package com.llx.producer;

import com.llx.domain.User;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * @version 1.0
 * @description
 * @author viki
 * @date 2021/8/20 23:08
 */
public class PSProducer {
    public static void main(String[] args) {
        // 1. 加载配置文件
        ClassPathXmlApplicationContext context =
                new ClassPathXmlApplicationContext("classpath:applicationContext-ps-producer.xml");
        // 2. 从spring容器中获取rabbitTemplate对象
        RabbitTemplate rabbitTemplate = (RabbitTemplate) context.getBean("rabbitTemplate");
        // 3. 准备User对象
        User user = new User(110,"张三",12);
        // 4. 发送消息到交换机
        /**
         * 参数1: 交互机名字
         * 参数2: 路由key
         * 参数3: 要发送的数据
         */
        rabbitTemplate.convertAndSend("ps_exchange","",user);
        // 如果需要程序停止,那么我们关闭容器即可
        context.close();
    }
}
